package com.dkd.quartz.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.quartz.SchedulerFactoryBean;
import javax.sql.DataSource;
import java.util.Properties;

/**
 * 定时任务配置（单机部署建议删除此类和qrtz数据库表，默认走内存会最高效）
 *
 * @author ruoyi
 */
@Configuration
public class ScheduleConfig
{
    @Bean
    public SchedulerFactoryBean schedulerFactoryBean(DataSource dataSource)
    {
        // 创建并配置SchedulerFactoryBean，用于定时任务的调度
        SchedulerFactoryBean factory = new SchedulerFactoryBean();
        // 设置数据源
        factory.setDataSource(dataSource);

        // 初始化Quartz属性
        Properties prop = new Properties();
        // 设置调度器实例名称
        prop.put("org.quartz.scheduler.instanceName", "RuoyiScheduler");
        // 设置调度器实例ID生成方式为自动
        prop.put("org.quartz.scheduler.instanceId", "AUTO");
        // 线程池配置
        // 设置线程池类型为SimpleThreadPool
        prop.put("org.quartz.threadPool.class", "org.quartz.simpl.SimpleThreadPool");
        // 设置线程池中的线程数量为20
        prop.put("org.quartz.threadPool.threadCount", "20");
        // 设置线程池中线程的优先级为5（5-10）
        prop.put("org.quartz.threadPool.threadPriority", "5");
        // JobStore配置
        // 使用LocalDataSourceJobStore作为JobStore
        prop.put("org.quartz.jobStore.class", "org.springframework.scheduling.quartz.LocalDataSourceJobStore");
        // 集群配置
        // 启用集群
        prop.put("org.quartz.jobStore.isClustered", "true");
        // 设置集群检查间隔时间为15秒
        prop.put("org.quartz.jobStore.clusterCheckinInterval", "15000");
        // 设置同时处理的最大误发数量为10
        prop.put("org.quartz.jobStore.maxMisfiresToHandleAtATime", "10");
        // 设置事务隔离级别为可序列化
        prop.put("org.quartz.jobStore.txIsolationLevelSerializable", "true");

        // 注释掉的SQL Server特定配置
        // prop.put("org.quartz.jobStore.selectWithLockSQL", "SELECT * FROM {0}LOCKS UPDLOCK WHERE LOCK_NAME = ?");
        // 设置误发阈值为12秒
        prop.put("org.quartz.jobStore.misfireThreshold", "12000");
        // 设置表前缀为QRTZ_
        prop.put("org.quartz.jobStore.tablePrefix", "QRTZ_");
        // 将Quartz属性设置到工厂中
        factory.setQuartzProperties(prop);

        // 设置调度器名称
        factory.setSchedulerName("RuoyiScheduler");
        // 延迟启动调度器
        factory.setStartupDelay(1);
        // 设置应用上下文在调度器上下文中的键
        factory.setApplicationContextSchedulerContextKey("applicationContextKey");
        // 覆盖已存在的作业，以便在修改目标对象后不需要删除对应的数据库记录
        factory.setOverwriteExistingJobs(true);
        // 启动时自动启动调度器
        factory.setAutoStartup(true);

        // 返回配置好的SchedulerFactoryBean
        return factory;
    }
}
